#!/bin/bash
echo "正在执行增量采集任务"
spark-sql -e "alter table ods.ods_base_acd_file_d_i add if not exists partition(pt='20250110')"
datax.py ./ods_base_acd_file_d_i.json
spark-sql -e "alter table ods.ods_base_bd_drivinglicense_d_i add if not exists partition(pt='20250110')"
datax.py ./ods_base_bd_drivinglicense_d_i.json
spark-sql -e "alter table ods.ods_base_bd_vehicle_d_i add if not exists partition(pt='20250110')"
datax.py ./ods_base_bd_vehicle_d_i.json
spark-sql -e "alter table ods.ods_base_vio_force_d_i add if not exists partition(pt='20250110')"
datax.py ./ods_base_vio_force_d_i.json
spark-sql -e "alter table ods.ods_base_vio_surveil_d_i add if not exists partition(pt='20250110')"
datax.py ./ods_base_vio_surveil_d_i.json
echo "增量采集任务完成"